package cn.tukk.sparkproject.spark.product.MyUDF;

import org.apache.spark.sql.api.java.UDF3;

/**
 * 几个参数就继承UDFn..
 */
public class MyConcatLongStringUDF implements UDF3<Long,String,String,String> {

    @Override
    public String call(Long v1, String v2,String split) throws Exception {
        return   String.valueOf(v1)+split+v2;
    }
}
